package org.apache.flink.runtime.client;

import org.apache.flink.api.common.ConsumerID;

/** An exception indicating that the consumer has failed in the INITIALIZING consumer status. */
public class ConsumerInitializationException extends ConsumeException {

    private static final long serialVersionUID = 2818087325120827526L;

    public ConsumerInitializationException(ConsumerID jobID, String msg, Throwable cause) {
        super(jobID, msg, cause);
    }
}
